TrafficHandler{
      contentRemove.getBytes("UTF-8");
}
messageReceived{
  ChannelBuffer msg=(ChannelBuffer)e.getMessage();
  if (channel.isWritable()) {
    trafficLogger.log(connectionId,"recv",num.incrementAndGet(),msg.array());
    Channels.write(channel,msg);
    e.getChannel().setReadable(false);
}
channelInterestChanged{
  if (e.getChannel().isWritable()) {
    channel.setReadable(true);
}
channelClosed{ }
exceptionCaught{
  e.getCause().printStackTrace();
  closeOnFlush(e.getChannel());
}
closeOnFlush{
  if (ch.isConnected()) {
    ch.write(ChannelBuffers.EMPTY_BUFFER).addListener(ChannelFutureListener.CLOSE);
}
